// 队列服务任务耗时示例

async function createExampleTask() {
  console.log('🚀 创建示例任务以测试耗时功能...');
  
  try {
    // 创建一个长时间运行的任务来更好地测试耗时
    const task = {
      type: 'long-running-task',
      index: 1,
      duration: 3 // 3秒
    };
    
    console.log('📥 提交长时间运行任务...');
    
    const response = await fetch('http://localhost:3003/api/queue/task', {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({ task })
    });
    
    if (response.ok) {
      const result = await response.json();
      console.log('✅ 任务提交成功:', result);
      console.log('⏳ 任务将在3秒后完成，请稍后查看历史记录中的耗时信息');
      
      // 等待任务完成
      await new Promise(resolve => setTimeout(resolve, 4000));
      
      // 获取历史记录
      console.log('\n📋 获取历史记录...');
      const historyResponse = await fetch('http://localhost:3003/api/queue/history');
      
      if (historyResponse.ok) {
        const historyResult = await historyResponse.json();
        
        // 查找我们刚刚添加的任务
        const taskHistory = historyResult.data.find(item => item.id === result.taskId);
        if (taskHistory) {
          console.log('\n📊 任务详情:');
          console.log('  任务ID:', taskHistory.id);
          console.log('  任务类型:', taskHistory.task?.type);
          console.log('  状态:', taskHistory.status);
          console.log('  耗时:', taskHistory.duration, 'ms');
          console.log('  开始时间:', new Date(taskHistory.startTime).toISOString());
          console.log('  结束时间:', new Date(taskHistory.endTime).toISOString());
        }
      }
    } else {
      console.error('❌ 任务提交失败:', response.status);
    }
    
    console.log('\n✅ 示例任务创建完成');
  } catch (error) {
    console.error('❌ 创建示例任务时发生错误:', error);
  }
}

// 运行示例
createExampleTask();